package com.xb.demo.pool;//package com.xb.bigdata.pool;
//
//import org.junit.Test;
//
//import java.util.Properties;
//
//public class kafkatest {
//
//    @Test
//    public void producerTest() throws Exception{
//        Properties props = new Properties();
//        props.put("bootstrap.servers", "58.218.201.170:9092,58.218.201.167:9092,58.218.203.29:9092");
//        props.put("acks", "all");
//        props.put("retries", 0);
//        props.put("batch.size", 16384);
//        props.put("linger.ms", 1);
//        props.put("buffer.memory", 33554432);
//        props.put("key.serializer",
//                "org.apache.kafka.common.serialization.StringSerializer");
//        props.put("value.serializer",
//                "org.apache.kafka.common.serialization.StringSerializer");
//
//        KafkaPool<String, String> pool=new KafkaPool<String, String>(props);
//        for(int i=0;i<1000;i++){
//            KafkaProducerApp<String, String> producer=pool.borrowProducer();
//            producer.send("vdata", "test"+i);
//            pool.returnProducer(producer);
//            System.out.println("-------------"+i);
//        }
//    }
//}
